package com.lollipop.rabbitmqspringboot.consumer;

/**
 * @Author: Lollipop
 * @Date: 2021-10-10 17:50
 * @Description: 基于RabbitMQ延时插件实现延时（由于没有当前使用的RabbitMQ没有安装延迟插件，先注释掉避免项目启动报错）
 */
//@Component
//@Slf4j
//public class DelayQueueConsumer {
//    /**
//     * 监听消息队列
//     *
//     * @param message
//     */
//    @RabbitListener(queues = DelayedQueueConfig.DELAYED_QUEUE_NAME)
//    public void receiveDelayQueue(Message message) {
//        String msg = new String(message.getBody());
//        log.info("当前时间：{}，收到的延时队列的消息：{}", LocalDateTime.now().toString(), msg);
//
//    }
//}
